# frozen_string_literal: true

module RubyEventStore
  module ActiveRecord
    class PgLinearizedEventRepository < EventRepository
      def start_transaction(&proc)
        ::ActiveRecord::Base.transaction(requires_new: true) do
          ::ActiveRecord::Base.connection.execute("SELECT pg_advisory_xact_lock(1845240511599988039) as l").each {}

          proc.call
        end
      end
    end
  end
end
